aae1be469450ed714cf0630dd4e04eb43df62d4c,threads/src/main/java/org/jboss/as/threads/ScheduledThreadPoolAdd.java,ScheduledThreadPoolAdd,performRuntime,#OperationContext#ModelNode#ModelNode#ServiceVerificationHandler#List#,78
Before Change
final ServiceVerificationHandler verificationHandler, final List<ServiceController<?>> newControllers) throws OperationFailedException {
for(final AttributeDefinition attribute : ATTRIBUTES) {
attribute.resolveModelAttribute(context, model);
}
final BaseOperationParameters params = ThreadsSubsystemThreadPoolOperationUtils.parseScheduledThreadPoolOperationParameters(operation);
ServiceTarget target = context.getServiceTarget();
final ServiceName serviceName = ThreadsServices.executorName(params.getName());
final ScheduledThreadPoolService service = new ScheduledThreadPoolService(params.getMaxThreads().getScaledCount(), params.getKeepAliveTime());
final ServiceBuilder<ManagedScheduledExecutorService> serviceBuilder = target.addService(serviceName, service);
ThreadsSubsystemThreadPoolOperationUtils.addThreadFactoryDependency(params.getThreadFactory(), serviceName, serviceBuilder, service.getThreadFactoryInjector(), target, params.getName() + "-threads");
serviceBuilder.addListener(verificationHandler);
serviceBuilder.install();
}
}
After Change
protected void performRuntime(final OperationContext context, final ModelNode operation, final ModelNode model,
final ServiceVerificationHandler verificationHandler, final List<ServiceController<?>> newControllers) throws OperationFailedException {
final ModelNode resolved = new ModelNode();
resolved.get(OP).set(operation.get(OP));
resolved.get(OP_ADDR).set(operation.get(OP_ADDR));
for(final AttributeDefinition attribute : ATTRIBUTES) {
resolved.get(attribute.getName()).set(attribute.resolveModelAttribute(context, model));
}
final BaseOperationParameters params = ThreadsSubsystemThreadPoolOperationUtils.parseScheduledThreadPoolOperationParameters(resolved);
ServiceTarget target = context.getServiceTarget();
final ServiceName serviceName = ThreadsServices.executorName(params.getName());
final ScheduledThreadPoolService service = new ScheduledThreadPoolService(params.getMaxThreads().getScaledCount(), params.getKeepAliveTime());
final ServiceBuilder<ManagedScheduledExecutorService> serviceBuilder = target.addService(serviceName, service);
ThreadsSubsystemThreadPoolOperationUtils.addThreadFactoryDependency(params.getThreadFactory(), serviceName, serviceBuilder, service.getThreadFactoryInjector(), target, params.getName() + "-threads");
if (verificationHandler != null) {
serviceBuilder.addListener(verificationHandler);
}
ServiceController<?> sc = serviceBuilder.install();
if (newControllers != null) {
newControllers.add(sc);
}
}